package com.example.artemis.factory;

import com.example.artemis.config.AbstractConsumerConfig;
import com.example.artemis.impl.QueueMessageConsumer;
import com.example.artemis.interfaces.MessageConsumer;
import com.example.artemis.interfaces.MessageConsumerFactory;

/**
 * 队列消息消费者工厂实现类
 * 负责创建QueueMessageConsumer实例
 */
public class QueueMessageConsumerFactory implements MessageConsumerFactory {

    @Override
    public MessageConsumer createConsumer(AbstractConsumerConfig config) {
        return new QueueMessageConsumer(config);
    }
}